#ifndef _MQTT_COMMUNICATION_H
#define _MQTT_COMMUNICATION_H

#include "mqtt.h"

int mqtt_communication_init(const char *addr, const char *port);
void publish_callback(void** unused, struct mqtt_response_publish *published);
void subscription_topic(const char *topic);
void public_message(const char *message, const int message_length, const char *topic, uint8_t publish_flags);
void* client_refresher(void* client);
void exit_example(int status, int sockfd, pthread_t *client_daemon);

#endif